package com.pie4cloud.pie.bus.service;

import com.pie4cloud.pie.bus.api.dto.ConsumerDto;
import com.pie4cloud.pie.bus.api.dto.MessageDto;
import com.pie4cloud.pie.common.core.util.R;

import java.util.List;


public interface KafkaSendService {

	R sendKafka(MessageDto messageDto);

	R sendKafkas(List<MessageDto> messageDtos);

	R sendConsumer(ConsumerDto consumerDto);



}
